Micron Document
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
| SparkN0de-git | SparkN0de |
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Node / ReticulumProjects / MeshChatX.git / commits / 83be395


Commit 83be39542583a4e012c608ef6412c5b973fcfe05

󰉖 Browse tree at this commit

Parents : 37fbd43
Author : Ivan <ivan@quad4.io>
Signature : Signature validation error
Date : 2026-05-06T16:10:42-05:00

refactor(async_utils): adjust coroutine management limits and add logging for dropped coroutines

Changes

1 files changed, 15 insertions(+), 1 deletions(-)

M meshchatx/src/backend/async_utils.py +15 -1

Diff

diff --git a/meshchatx/src/backend/async_utils.py b/meshchatx/src/backend/async_utils.py
index 23bb5bc1..9230808d 100644
--- a/meshchatx/src/backend/async_utils.py
+++ b/meshchatx/src/backend/async_utils.py
@@ -12,7 +12,8 @@ class AsyncUtils:
_pending_futures: ClassVar[list[Any]] = []
_pending_coroutines: ClassVar[list[Any]] = []
_futures_lock = threading.Lock()
- _FUTURES_SWEEP_THRESHOLD = 64
+ _FUTURES_SWEEP_THRESHOLD = 32
+ _COROUTINES_MAX = 256
@staticmethod
def apply_asyncio_313_patch():
@@ -80,4 +81,17 @@ class AsyncUtils:
]
return
+ # If the loop isn't available yet (or has stopped), buffer the coroutine
+ # but cap the backlog so we don't leak memory indefinitely.
AsyncUtils._pending_coroutines.append(coroutine)
+ if len(AsyncUtils._pending_coroutines) > AsyncUtils._COROUTINES_MAX:
+ dropped = len(AsyncUtils._pending_coroutines) - AsyncUtils._COROUTINES_MAX
+ AsyncUtils._pending_coroutines = AsyncUtils._pending_coroutines[
+ -AsyncUtils._COROUTINES_MAX :
+ ]
+ import logging
+
+ logging.getLogger("meshchatx.async").warning(
+ "Dropped %d buffered coroutine(s) because the event loop is not running",
+ dropped,
+ )


──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────